c443245b12e7e4272ab006c51851396374877ff8,modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractMetricsSelfTest.java,GridCacheAbstractMetricsSelfTest,checkTtl,#boolean#,703
Before Change
for (int i = 0; i < gridCount(); i++) {
if (grid(i).affinity(null).isPrimaryOrBackup(grid(i).localNode(), key)) {
GridCacheEntryEx<Object, Object> curEntry =
((IgniteKernal)grid(0)).internalCache().entryEx(key);
assertEquals(ttl, curEntry.ttl());
assertEquals(expireTimes[i], curEntry.expireTime());
After Change
c.put(key, 1);
GridCacheAdapter<Object, Object> c0 = ((IgniteKernal)grid(0)).internalCache();
if (c0.isNear())
c0 = c0.context().near().dht();
GridCacheEntryEx entry = c0.entryEx(key);
assert entry != null;
assertEquals(0, entry.ttl());
assertEquals(0, entry.expireTime());
long startTime = System.currentTimeMillis();
if (inTx) {
// Rollback transaction for the first time.
IgniteTx tx = grid(0).transactions().txStart();
try {
grid(0).jcache(null).withExpiryPolicy(expiry).put(key, 1);
}
finally {
tx.rollback();
}
entry = ((IgniteKernal)grid(0)).internalCache().entryEx(key);
assertEquals(0, entry.ttl());
assertEquals(0, entry.expireTime());
}
// Now commit transaction and check that ttl and expire time have been saved.
IgniteTx tx = inTx ? grid(0).transactions().txStart() : null;
try {
grid(0).jcache(null).withExpiryPolicy(expiry).put(key, 1);
}
finally {
if (tx != null)
tx.commit();
}
long[] expireTimes = new long[gridCount()];
for (int i = 0; i < gridCount(); i++) {
if (grid(i).affinity(null).isPrimaryOrBackup(grid(i).localNode(), key)) {
c0 = ((IgniteKernal)grid(i)).internalCache();
if (c0.isNear())
c0 = c0.context().near().dht();
GridCacheEntryEx<Object, Object> curEntry = c0.peekEx(key);
assertEquals(ttl, curEntry.ttl());